package com.xtxb.app.rmq.common;

import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;

public class MyMQConsume extends DefaultMQPushConsumer {
    private long createTime;

    public MyMQConsume(String groupName) {
        super(groupName);
        createTime=System.currentTimeMillis();
    }

    public long getCreateTime() {
        return createTime;
    }
}
